package com.yifeng.repo.flink.data.transport.config;

import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;

import lombok.Data;

@Data
public class SinkDbConfig extends DataSourceConfig implements Serializable {

	private static final long serialVersionUID = 1L;
	
	private int poolSize;
	
	private Map<String,String> pkMap = new HashMap<String,String>();
	
	private String keyWord;
	
	private boolean isNeedTransferKeyWord;
	
	private String keyWordSupplement;
	
	private String needDealKeywordTable;
	
	private Map<String,String> tableMappingMap = new HashMap<String,String>();
}
